package com.xframe.event.bus.core.msg;

import com.rabbitmq.client.AMQP;
import com.rabbitmq.client.Envelope;
/**
 * 处理消息的接口
 *
 * @author xufeng
 * @version 1.0
 * @date 2022-09-19
 */
public interface IMsgProc {

    /**
     * 消息接收入口函数
     * @param consumerTag 用户自定义的tag
     * @param envelope 消息的环境上下文对象,可以获得队列名称,路由key等参数
     * @param properties 附加属性
     * @param msg 消息
     */
    void proc(String consumerTag, Envelope envelope, AMQP.BasicProperties properties,String msg);
}
